package gsw.tool.rxjava;

/**
 * 观察者
 */
public abstract class Observer<T> {
    /**
     * 观察者处理通知
     *
     * @param t 被观察者发送的数据
     */
    public abstract void onNext(T t);

    /**
     * 观察者处理错误事件
     */
    public abstract void onError(Throwable e);

    /**
     * 观察者处理完成事件
     */
    public abstract void onComplete();
}
